
object CollectRdd {
  // 定义PartialFunction偏函数
  val one: PartialFunction[Int, String] = {
    case 1 => "one"
    case _ => "other" // 通配符处理所有其他情况
  }
  def main(args:Array[String]):Unit = {
    // 创建测试数据RDD
    //val data = sc.parallelize(Seq(2, 3, 1))

    // 应用偏函数并收集结果
    //val result = data.collect(one).collect()

    // 打印验证结果
    //result.foreach(println)
  }

}
